package demo.binder;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface InputBinding {

    //接收队列1
    String INPUT_1 = "input_1";

    //接收队列1
    String INPUT_2 = "input_2";

    @Input(InputBinding.INPUT_1)
    SubscribableChannel input1();

    @Input(InputBinding.INPUT_2)
    SubscribableChannel input2();
}
